package com.zte.claa.inficombo.csa.app.service.redis;

import org.springframework.data.redis.core.StringRedisTemplate;

public class CSAMessagePublisher {
	// redis string template.
	private StringRedisTemplate redisStrTemplate;
	// topic
	private String redisChannel;
	
	/**
	 * 构建器
	 * 
	 * @param redisStrTemplate
	 * @param redisChannel
	 */
	public CSAMessagePublisher(StringRedisTemplate redisStrTemplate, String redisChannel){
		this.redisStrTemplate = redisStrTemplate;
		this.redisChannel = redisChannel.trim();
	}
	
	/**
	 * 发布消息
	 * 
	 * @param message
	 */
	public void publishMessage(String message){
		this.redisStrTemplate.convertAndSend(this.redisChannel, message);
	}
	
}
